package cn.doitedu.demo5;

import cn.doitedu.demo1.UserEvent_1;
import org.apache.flink.api.common.functions.RuntimeContext;
import org.apache.flink.util.Collector;

import java.io.IOException;

public interface RuleCalculator {


    /**
     * 交给运算机实现类，去实现一些自己所需的初始化逻辑
     * @param runtimeContext
     */
    void init(RuntimeContext runtimeContext) throws IOException;

    /**
     * 交给运算机实现类，去实现自己的数据处理逻辑
     * @param eventBean
     * @param out
     */
    void calc(UserEvent_1 eventBean,Collector<String> out) throws IOException;
}
